import * as mq from '../mq/index';

setInterval(async () => {
    await mq.producer('fuck', {'come': 'on'});
}, 1000);
